package produce.controller;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author Kevin
 * @date 2023/6/11 13:10
 * @description 路由模式消息
 * 指定路由key的发布订阅模式
 **/
@RequestMapping("/routing")
@RestController
public class RoutingController {

  @Autowired
  private RabbitTemplate rabbitTemplate;

  /**
   * 发布消息，需要指定交换机
   * @param msg 消息
   * @param key 路由key
   * @return
   */
  @GetMapping
  public String send(String msg,String key){

    // 第一次为交换机名 第二个为路由key 第三个为消息
    rabbitTemplate.convertAndSend("routing-exchange",key,msg);

    return "发送路由模式消息成功";
  }

}
